package config

import (
	"github.com/nats-io/nats.go"
	"github.com/sirupsen/logrus"
	"sync"
)

var natsConn *nats.Conn
var once4 sync.Once // 确保初始化只执行一次的同步工具

// InitNats 初始化Nats连接
func InitNats(endpoint string) {
	once4.Do(func() {
		//连接Nats
		nc, err1 := nats.Connect(endpoint)
		if err1 != nil {
			logrus.Fatal("连接Nats出错。", err1)
		}
		natsConn = nc
	})
}

func GetNatsConn() *nats.Conn {
	return natsConn
}
